package com.example.telesys.service;

import com.example.telesys.pojo.Supplier;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Service;


/**
 * 注意topic要与 发送消息那里指定的topic一致
 * 这样才能准确收到消息
 * 而且要注意泛型的类型 是自己发送的消息体 而不能任意指定 这里是list
 */
@Service
@RocketMQMessageListener(consumerGroup = "tele-user", topic = "supplier-topic")
public class SmsService implements RocketMQListener<Supplier> {
    //具体监听的函数
    @Override
    public void onMessage(Supplier supplier) {
        System.out.println("收到一个Supplier消息====>" + supplier);
        System.out.println("接下来发送短信！");
    }
}
